package org.qee.mq.custom;

import java.util.List;

public interface Consumer<T> {

    List<T> poll();

    List<T> poll(long offset);
}
